package com.example.d7_thread_communication;

import java.util.ArrayList;
import java.util.List;

public class Desk {
    // 放包子的集合
    private List<String> list = new ArrayList<>();

    // 注意：线程通信的前提是线程安全
    // 放1个包子的方法
    // 厨师1 厨师2 厨师3
    public synchronized void put() {
        try {
            String name = Thread.currentThread().getName();
            // 判断是否有包子
            if (list.isEmpty()) {
                list.add(name + "做的肉包子");
                System.out.println(name + "做了一个包子");
                Thread.sleep(2000);
                /*
                object类的等待和唤醒方法
                wait()方法：让当前线程等待并释放锁,知道另外一个线程调用notify()方法或notifyAll()方法
                notify()方法：唤醒一个正在等待的单个线程
                notifyAll()方法：唤醒所有正在等待的所有线程
                注意：上述的方法应该使用同步锁对象进行调用否则会出现bug
                 */
                // 等待自己,唤醒别人 注意：而且应该是唤醒别人在等待,如果你先等待自己了,还怎么唤醒别人
                this.notifyAll();
                this.wait();
            } else {
                // 等待自己,唤醒别人
                this.notifyAll();
                this.wait();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    // 吃货1 吃货2
    public synchronized void get() {
        try {
            String name = Thread.currentThread().getName();
            if (list.size() == 1) {
                // 有包子,吃掉一个
                System.out.println(name + "吃了一个" + list.get(0));
                list.clear();
                Thread.sleep(1000);
                // 等待自己,唤醒别人
                this.notifyAll();
                this.wait();
            }else {
                // 说明没有包子,也应该等待自己,唤醒别人
                this.notifyAll();
                this.wait();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
